b6c99e0901fde933b273be1833fc70b06a32173f,integration/src/integration/java/pl/allegro/tech/hermes/integration/BatchDeliveryTest.java,BatchDeliveryTest,shouldDeliverAvroMessagesAsJsonBatch,#,101

Before Change


        AvroUser user = new AvroUser("Bob", 50, "blue");

        Topic topic = topic("batch.avro.topic")
                .withValidation(true)
                .withMessageSchema(user.getSchemaAsString())
                .withContentType(AVRO).build();
        operations.buildTopic(topic);

        operations.createBatchSubscription(topic, HTTP_ENDPOINT_URL, buildBatchPolicy()

After Change


        // given
        AvroUser user = new AvroUser("Bob", 50, "blue");

        Topic topic = topic("batch.avro.topic")
                .withValidation(true)
                .withContentType(AVRO).build();
        operations.buildTopic(topic);
        operations.saveSchema(topic, user.getSchemaAsString());

        operations.createBatchSubscription(topic, HTTP_ENDPOINT_URL, buildBatchPolicy()
                .withBatchSize(2)